/**
* @Title: ServerObjectHandler.java
* @Package com.an.objecttran
* @Description: TODO(用一句话描述该文件做什么)
* @author antch,861710865@qq.com
* @date 2017年7月26日 下午3:04:06
* @version V1.0
*/


package com.an.objecttran;

import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
* @ClassName: ServerObjectHandler
* @Description: TODO(服务端处理传入与输出的对象)
* @author antch,861710865@qq.com
* @date 2017年7月26日 下午3:04:06
*
*/

public class ServerObjectHandler extends SimpleChannelInboundHandler<Dog> {

	@Override
	protected void channelRead0(ChannelHandlerContext ctx, Dog dog) throws Exception {
		// TODO Auto-generated method stub
		System.out.println("读取到客户端发送的对象：" + dog);
		ctx.writeAndFlush("hello 我已读到你发送的对象");

	}


	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		Channel incoming = ctx.channel();
		System.out.println("SimpleChannelClient:" + incoming.remoteAddress() + "异常");
		//当出现异常，关闭连接
		cause.printStackTrace();
		ctx.close();
	}

}
